package com.ruoyi.server.read;

import com.ruoyi.server.person.PassageWayUser;
import com.ruoyi.server.pkg.SendMsg;
import io.netty.channel.ChannelHandlerContext;
import org.springframework.stereotype.Component;

/**
 * 上线拉去消息处理
 *      留点: 1、按照时间线处理, 时间线如果为空则最大推一个月内的消息
 *           2、当按照时间线处理后, 消息数量还是大于 > 5000, 默认处理前5000条, 如果需要重新拉取
 *
 *           TODO 6.09 这里应该是对数据存储操作相关的接口了
 *
 * @author OpenACloud
 * @create 2024/6/3 22:09
 */
@Component
public interface BasePullReader {

    public void saveMessages(SendMsg sendMsg);

    public void pullMessages(ChannelHandlerContext ctx, PassageWayUser wayUser);
}
